package taskjob

import (
	"context"
	"github.com/beego/beego/v2/task"
	"ksd-social-api/utils/rdb"
)

// 定义初始化的任务类
func InitTask() {
	// 开始执行一个任务
	// 参数1：任务的名称
	// 参数2：cron表达式
	// 参数3：当前tk1这个定时具体要做什么事情
	tk := task.NewTask("tk1", "59 59 23 * * ?", GenerateWarning)
	// 添加任务到队列中
	task.AddTask("tk1", tk)
}

// tk2具体要做的事情，在这里进行编写 ---秒杀商品加载到redis中
func GenerateWarning(context.Context) error {
	// 业务
	rdb.RdbDel("online_users")
	return nil
}
